SparkN0de-git - /page/commit.mu

Micron Document

--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

| SparkN0de-git | SparkN0de |

Node / ReticulumProjects / LXMF.git / commits / 1b5dc41

Commit 1b5dc419b5e56cb4a284032f31ef057a1243e3fb

󰉖 Browse tree at this commit

Parents : 9c5fa4a 557887d

Author : Mark Qvist <mark@unsigned.io>

Date : 2025-11-02T11:38:15+01:00

Merge messagestore check

Diff

diff --cc LXMF/LXMRouter.py

index 41b9618,27ea071..bde1cda

--- a/LXMF/LXMRouter.py

+++ b/LXMF/LXMRouter.py

@@@ -1088,12 -1088,12 +1088,13 @@@ class LXMRouter

now = time.time()

removed_entries = {}

for transient_id in self.propagation_entries.copy():

-- entry = self.propagation_entries[transient_id]

-- filepath = entry[1]

- filename = os.path.split(filepath)[-1]

- components = filename.split("_")

++ entry = self.propagation_entries[transient_id]

++ filepath = entry[1]

+ stamp_value = entry[6]

- components = filepath.split("_")

++ filename = os.path.split(filepath)[-1]

++ components = filename.split("_")

- if len(components) >= 3 and float(components[1]) > 0 and len(os.path.split(components[0])[1]) == (RNS.Identity.HASHLENGTH//8)*2 and int(components[2]) == stamp_value:

- if len(components) == 2 and float(components[1]) > 0 and len(components[0]) == (RNS.Identity.HASHLENGTH//8)*2:

++ if len(components) == 3 and float(components[1]) > 0 and len(os.path.split(components[0])[1]) == (RNS.Identity.HASHLENGTH//8)*2 and int(components[2]) == stamp_value:

timestamp = float(components[1])

if now > timestamp+LXMRouter.MESSAGE_EXPIRY:

RNS.log("Purging message "+RNS.prettyhexrep(transient_id)+" due to expiry", RNS.LOG_EXTREME)

──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────